api_version: Официальное API
description:
type: operator
doc_status: ready
status: не готовоAirbyteCreateConnetctionOperator
Создает новый Airbyte Connection.
airbyte_conn_id (см. Общие аргументы)name — название Airbyte Connection, которое нужно создатьsource_id или source_name— ID или название Airbyte Source, который нужно использовать. Если передан аргумент source_name, то становится обязательным аргумент sources_list. В этот аргумент нужно передать результат вызова оператора AirbyteListSourcesOperator.destination_id или destination_name— ID или название Airbyte Destination, который нужно использовать. Если передан аргумент source_name, то становится обязательным аргумент destinations_list. В этот аргумент нужно передать результат вызова оператора AirbyteListDestinationsOperator.params, который содержит следующие параметры:
configurations — параметры стримовschedule — параметры расписания запускаnamespaceDefinition — правила нейминга таблиц с данными: destination (по умолчанию), source или custom_format. Если задан custom_format, то можно также задать namespaceFormatprefix — префикс, который будет прибавляться к названиям таблицnonBreakingSchemaUpdatesBehavior (по умолчанию ignore)status — active, inactive или deprecatedСловарь с параметрами созданного Airbyte Connection, в т. ч. connectionId.